package initalize

//func InitRocker(orderListener *handler.OrderListener) {
//	var err error
//	global.RocketMQProducer, err = rocketmq.NewTransactionProducer(
//		orderListener,
//		producer.WithNsResolver(primitive.NewPassthroughResolver([]string{fmt.Sprintf("%s:%d", global.ServerConfig.RocketMq.Host, global.ServerConfig.RocketMq.Port)})),
//		//producer.WithRetry(1),
//	)
//	if err != nil {
//		zap.S().Panicf("生成 producer 失败: %s", err.Error())
//	}
//
//	if err = global.RocketMQProducer.Start(); err != nil {
//		zap.S().Panicf("启动 producer 失败: %s", err.Error())
//	}
//}
